package com.aiwiown.snackmq.api;

import com.aiwiown.snackmq.common.message.Message;

import java.util.List;

/**
 * 批量消息监听器接口
 * <p>
 * 业务方实现此接口来批量处理消费到的消息，以提高性能。
 */
public interface BatchMessageListener {
    /**
     * 消费一批消息
     * @param messages 接收到的消息列表
     * @return 消费结果。RETRY 将导致整个批次被重试。
     */
    ConsumeResult consume(List<Message> messages);
}